packages/drizzle/__tests__/drizzle.test.ts (1)

125-143: ⚡ Quick win

Consider centralizing the shared protect-ci DDL into a single helper.

This PR exists precisely because the union schema DDL was kept in sync manually across three files and a column was missed in one of them (PR #400). Extracting the CREATE TABLE IF NOT EXISTS + ALTER TABLE ADD COLUMN IF NOT EXISTS block into a shared test-fixture helper (e.g., packages/test-helpers/setupProtectCi.ts) would make any future column addition a one-line change and eliminate drift by construction.

💡 Suggested approach

// packages/test-helpers/setupProtectCi.ts (new file)
+ import postgres from 'postgres'
+
+ export async function setupProtectCiTable(databaseUrl: string): Promise<void> {
+   const sql = postgres(databaseUrl, { prepare: false })
+   try {
+     await sql`
+       CREATE TABLE IF NOT EXISTS "protect-ci" (
+         id INTEGER PRIMARY KEY GENERATED ALWAYS AS IDENTITY,
+         email eql_v2_encrypted,
+         age eql_v2_encrypted,
+         score eql_v2_encrypted,
+         profile eql_v2_encrypted,
+         encrypted eql_v2_encrypted,
+         "otherField" TEXT,
+         created_at TIMESTAMPTZ DEFAULT NOW(),
+         test_run_id TEXT
+       )
+     `
+     await sql`ALTER TABLE "protect-ci" ADD COLUMN IF NOT EXISTS "otherField" TEXT`
+   } finally {
+     await sql.end()
+   }
+ }

Each beforeAll would then call await setupProtectCiTable(process.env.DATABASE_URL as string) instead of inlining the DDL.

🤖 Prompt for AI Agents

Verify each finding against the current code and only fix it if needed.

In `@packages/drizzle/__tests__/drizzle.test.ts` around lines 125 - 143, Extract
the duplicated CREATE TABLE IF NOT EXISTS / ALTER TABLE ADD COLUMN IF NOT EXISTS
block into a single test helper (e.g., export async function
setupProtectCiTable(databaseUrl: string) in
packages/test-helpers/setupProtectCi.ts) and replace the inlined SQL in
packages/drizzle/__tests__/drizzle.test.ts (and the other two test files that
currently inline the same DDL) with a call to await
setupProtectCiTable(process.env.DATABASE_URL as string); ensure the helper opens
a DB client, runs the CREATE TABLE and ALTER TABLE statements exactly as before,
and closes the client so adding future columns is a single change.